const express = require('express')
const app = express()

var MongoClient = require('mongodb').MongoClient;
var url = "mongodb://localhost:27017/";

// 定义局部生效的中间件
const mw1 = (req, res, next)=>{
    MongoClient.connect(url, function(err, db) {
        if (err) throw err;
        var dbase = db.db("runoob");   // 创建的数据库名【runoob】
        var whereStr = {"type":'cn'}  // 查询的条件
        var updateStr = {$set:{'age':'10'}}  // 修改成这个
        // 更新一条数据
        // dbase.collection("site").updateOne(whereStr,updateStr,(err, result)=>{
        //     if(err) throw err
        //     console.log("文档更新成功");
        //     db.close();
        // })

        // 更新多条数据
        dbase.collection("site").updateMany(whereStr,updateStr,(err, res)=>{
            if(err) return err;
            console.log(res.result.nModified+"条数据被更新");
            db.close();
        })
    });
}

// 创建路由
app.get('/',mw1,(req, res) => {
    res.send('我是路由')
})

//配置端口
app.listen(80, ()=>{
    console.log("端口号为：http://127.0.0.1");
})
